Node / meshtastic / Meshtastic-Android / files / app / src / test / java / com / geeksville / mesh / service / MeshCommandSenderQueueTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2025-2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787com.geeksville.mesh.service

Tff7b72import T7ee787io.mockk.every

Tff7b72import T7ee787io.mockk.mockk

Tff7b72import T7ee787io.mockk.verify

Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow

Tff7b72import T7ee787kotlinx.coroutines.flow.asStateFlow

Tff7b72import T7ee787okio.ByteString

Tff7b72import T7ee787org.junit.Before

Tff7b72import T7ee787org.junit.Test

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.service.ConnectionState

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72class T56d364MeshCommandSenderQueueTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3packetHandler Tff7b72= Te6edf3mockkTff7b72<Te6edf3PacketHandlerTff7b72>Tb4b4b4(Te6edf3relaxed Tff7b72= Tff7b72trueTb4b4b4)

Tff7b72private Tff7b72val Te6edf3connectionStateHandler Tff7b72= Te6edf3mockkTff7b72<Te6edf3ConnectionStateHandlerTff7b72>Tb4b4b4(Te6edf3relaxed Tff7b72= Tff7b72trueTb4b4b4)

Tff7b72private Tff7b72val Te6edf3connectionStateFlow Tff7b72= Te6edf3MutableStateFlowTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4)

Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3commandSenderTb4b4b4: Te6edf3MeshCommandSender

Tf0883e@Before

Tff7b72fun Td2a8ffsetUpTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3every Tb4b4b4{ Te6edf3connectionStateHandlerTb4b4b4.Te6edf3connectionState Tb4b4b4} Te6edf3returns Te6edf3connectionStateFlowTb4b4b4.Te6edf3asStateFlowTb4b4b4(Tb4b4b4)

Te6edf3commandSender Tff7b72= Te6edf3MeshCommandSenderTb4b4b4(Te6edf3packetHandlerTb4b4b4, Tff7b72nullTb4b4b4, Te6edf3connectionStateHandlerTb4b4b4, Tff7b72nullTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`sendData queues TEXT_MESSAGE_APP when disconnected`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packet Tff7b72= Te6edf3DataPacketTb4b4b4(Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected

Te6edf3commandSenderTb4b4b4.Te6edf3processQueuedPacketsTb4b4b4(Tb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`sendData queues ATAK_PLUGIN when disconnected`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packet Tff7b72= Te6edf3DataPacketTb4b4b4(Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3ATAK_PLUGINTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected

Te6edf3commandSenderTb4b4b4.Te6edf3processQueuedPacketsTb4b4b4(Tb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`sendData queues ATAK_FORWARDER when disconnected`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packet Tff7b72= Te6edf3DataPacketTb4b4b4(Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3ATAK_FORWARDERTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected

Te6edf3commandSenderTb4b4b4.Te6edf3processQueuedPacketsTb4b4b4(Tb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`sendData queues DETECTION_SENSOR_APP when disconnected`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packet Tff7b72= Te6edf3DataPacketTb4b4b4(Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3DETECTION_SENSOR_APPTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected

Te6edf3commandSenderTb4b4b4.Te6edf3processQueuedPacketsTb4b4b4(Tb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`sendData queues PRIVATE_APP when disconnected`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packet Tff7b72= Te6edf3DataPacketTb4b4b4(Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3PRIVATE_APPTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected

Te6edf3commandSenderTb4b4b4.Te6edf3processQueuedPacketsTb4b4b4(Tb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`sendData does NOT queue IP_TUNNEL_APP when disconnected`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packet Tff7b72= Te6edf3DataPacketTb4b4b4(Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3IP_TUNNEL_APPTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected

Te6edf3commandSenderTb4b4b4.Te6edf3processQueuedPacketsTb4b4b4(Tb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tb4b4b4}